package com.zhuanzhuan.youpin.service;

import java.util.List;

import com.zhuanzhuan.youpin.entity.FailedMsg;
import com.zhuanzhuan.youpin.entity.EHandleStatus;

public interface IConsumerService {

    public void test();

    /**
     * @param topic
     * @param tags
     * @return
     * @author zz.youpin.G_Y
     * @date 2018年6月13日
     * @说明:根据topic&tags 获取未处理成功的msg
     * 最大获取数量1000
     */
    public List<FailedMsg> getFailedMsgByTopicAndTags(String topic, String tags);

    /**
     * @param failedMsg
     * @return
     * @author zz.youpin.G_Y
     * @date 2018年6月13日
     * @说明:新增失败消息
     */
    public Integer addFailedMsg(FailedMsg failedMsg);

    /**
     * @param failedMsg
     * @return
     * @author zz.youpin.G_Y
     * @date 2018年6月13日
     * @说明:处理完成、无论成功与否
     */
    public Integer onesEnd(Long failedMsgId, EHandleStatus status);

    /**
     * @param topic
     * @param tags
     * @param body
     * @return
     * @author zz.youpin.G_Y
     * @date 2018年6月13日
     * @说明:mq return true
     */
    public Integer onecMqSuccess(String topicAndTags, String bodyHash);

}
